package com.crt.uav.rabbitmq.consumer.listener;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.core.Message;
import org.springframework.stereotype.Component;

import com.crt.uav.rabbitmq.consumer.AbstractExtChannelAwareMessageListener;
import com.rabbitmq.client.Channel;

@Component
public class UavLogMessageListener extends AbstractExtChannelAwareMessageListener {

   //泵站日志队列
    private String queueName = "uav.log.queue";


    // @Autowired(required = false)
    // @Qualifier("thRabbitMqTemplate")
    // private RabbitTemplate thRabbitMqTemplate;

    private static final Logger LOGGER = LoggerFactory.getLogger(UavLogMessageListener.class);

    @Override
    protected void handleMessage(Message message, Channel channel) {
        // 这里可以添加处理逻辑，例如解析消息内容、存储到数据库等
    }

    @Override
    public String getQueueName() {
        return queueName;
    }

}
